package I

import rx.Observable
import java.util.concurrent.TimeUnit


fun main(args: Array<String>) {

    Observable.interval(500,TimeUnit.MILLISECONDS)
            .buffer(2,3)
            .subscribe({
                println(it)
            })
}